package com.sky.business.sys.queue;

import com.sky.business.sys.domain.MQTTMessage;

import java.util.concurrent.ConcurrentLinkedQueue;

public class MQTTMessageQueueConfig {

    private static final ConcurrentLinkedQueue<MQTTMessage> queue = new ConcurrentLinkedQueue<>();

    public static void offer(MQTTMessage mqttMessage){
        queue.offer(mqttMessage);
    }

    public static MQTTMessage poll(){
        return queue.poll();
    }


}
